package app.htby.utils;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

@Component
public class KafkaUtils {
	
	/** 监控系统 组 */
	public static String monitro_group_id;
	/** kafka 监控系统：内存、cpu的 topic */
	public static String monitor_topic;
	
	@Value("${kafka.monitorServerConfig.monitor_topic}")
	public void setMonitorTopic(String monitor_topic) {
		KafkaUtils.monitor_topic = monitor_topic;
	}
	
	@Value("${kafka.monitorServerConfig.group.id}")
	public void setMonitorGroupId(String monitro_group_id) {
		KafkaUtils.monitro_group_id = monitro_group_id;
	}
}
